package com.fxu.framework.mq.redis.simple;

/**
 * {@link RedisMqMessage} 消息拦截器
 * 通过拦截器，作为插件机制，实现拓展。
 * 例如说，多租户场景下的 MQ 消息处理
 *
 * @author fangxu
 */
public interface RedisMqInterceptor {

    default void sendMessageBefore(RedisMqMessage message) {
    }

    default void sendMessageAfter(RedisMqMessage message) {
    }

    default void consumeMessageBefore(RedisMqMessage message) {
    }

    default void consumeMessageAfter(RedisMqMessage message) {
    }

}
